package org.idea.qiyu.framework.canal.handle;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.alibaba.otter.canal.protocol.Message;
import com.google.protobuf.InvalidProtocolBufferException;

import java.util.List;

/**
 * @Author idea
 * @Date created in 10:08 上午 2020/8/2
 */
public interface ICanalHandler {

    /**
     * 数据删除回调
     *
     * @param rowChange
     */
    void onDelete(CanalEntry.RowChange rowChange);

    /**
     * 数据更新回调
     *
     * @param rowChange
     */
    void onUpdate(CanalEntry.RowChange rowChange);

    /**
     * 数据写入回调
     *
     * @param rowChange
     */
    void onInsert(CanalEntry.RowChange rowChange);

    /**
     * 消费canal发送过来的消息
     *
     * @param message
     */
    void consume(Message message);
}

